package com.lry.message;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;
import java.util.List;

@Data
@AllArgsConstructor
@NoArgsConstructor
public class AckMessage implements Serializable {

    private String topic;
    private String group;
    private int queueIndex;
    private List<Long> consumeOffsets;

}
